Alteryx SDKのPython SDK

「カスタマーストーリー」を支えるツール特集

#Python

#Alteryx SDK

#ビッグデータ

#Alteryx

じょんすみす

2018.02.20

この記事は公開されてから1年以上経過しています。情報が古い可能性がありますので、ご注意ください。

こんにちは、小澤です。

このシリーズではこれまでAlteryx SDKを構成する要素として、Configファイル, HTML GUIと紹介してきました。また、それらを使ったサンプルマクロの作成も行いました。 Alteryx SDKでは処理内容の部分もマクロではなくプログラムとして記述することが可能です。

今回は、Pythonを使った処理内容の実装方法を解説していきたいと思います。

なお、Alteryx 11.8現在、Python SDKはベータ版となっています。今後、仕様に破壊的変更が加わる可能性があるのでご注意ください。

Python SDKのメソッド

Pythonでプログラムを記述する際には、処理内容の他にワークフローのXMLに設定された値を取得するなどの部分も含めて記述する必要があります。 Alteryx上で「この操作を行った時にこの処理を実行する」という対応関係を記載する必要があります。 AlteryxのPython SDKではそれら特定のイベントに対応する処理を記述するための2つのクラスを実装します。

AyxPlugin

AyxPluginでは、主にツールがワークフロー中に配置された際の挙動を設定します。実装するメソッドは以下になります。

メソッド	役割
__init__	ツールがワークフローに配置された際に呼び出されるコンストラクタ
pi_init	ツールの選択状態が解除された時(設定値が利用可能になった時)に呼び出される
pi_add_incoming_connection	入力コネクションが接続された時の動作を設定
pi_add_outcoming_connection	出力コネクションが設定された時の動作を設定
pi_push_all_records	入力がない(あるいはオプション)のツールで初期値を設定する
pi_close	終了処理

これらのメソッドを実行する処理は記述する必要はなく、Alteryxから呼び出されます。クラス内にはその他にもヘルパなどのメソッドを定義しても問題ありません。

記述内容は以下のようになります。

class AyxPlugin:
    def __init__(self, n_tool_id: int, alteryx_engine: object, output_anchor_mgr: object):
        # 引数で受け取ったものや各種内部処理必要な設定をメンバ変数として初期化・保存
        
    def pi_init(self, str_xml: str):
        # ワークフローの設定値が渡されるので、XMLをパースして値を取得する
        
    def pi_add_incoming_connection(self, str_type: str, str_name: str) -> object:
        # 入力コネクションが設定された際にメタデータがわたるので必要な処理を行う
        # IncomingInterfaceをインスタンス化する
        
    def pi_add_outgoing_connection(self, str_name: str) -> bool:
        # 出力に関する設定を行う

    def pi_push_all_records(self, n_record_limit: int) -> bool:
        # 初期値として必要な値の設定を行う
        
    def pi_close(self, b_has_errors: bool):
        # 終了処理

IncomingInterface

IncomingInterfaceでは主にワークフローが実行された際の動作に関する設定を行いいます。

メソッド	役割
__init__	pi_incoming_connectionでインスタンス化された際に呼び出される
ii_init	入力コネクションから受け取るメタ情報が変更された際に呼び出される
ii_push_records	ワークフロー実行時にデータ1行ごとに対して実行される処理
ii_update_progress	ツールの進捗状況(パーセンテージ)を返す
ii_close	終了処理

コンストラクタを除き、こちらもAlteryxから呼び出されるメソッドとなります。

class IncomingInterface:
    def __init__(self, parent: object):
        # インスタンスが生成された際の初期化を行う
        
    def ii_init(self, record_info_in: object) -> bool:
        # 入力コネクションのメタデータが変化した際に呼び出されるので必要な初期化や出力に関するメタデータの設定を行う
        
    def ii_push_record(self, in_record: object) -> bool:
        # ワークフローが実行された際に各レコードごとに「in_record」に値が渡される
        # ここで具体的な処理内容を記述する

    def ii_update_progress(self, d_percent: float):
        # 処理の進捗状況を返す

    def ii_close(self):
        # 終了処理